package com.hu.common;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

/**
 * @Author: hujianjun
 * @Date: 2021/2/3 22:51
 * @Describe: 生成flink整体代码模板
 */
public class FlinkCodeModule {
    public static void main(String[] args) throws Exception {
        //TODO 1.获取执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        //TODO 2.读取数据源

        //TODO 3.转换操作

        //TODO 4.sink操作

        //TODO 5.执行程序
        env.execute();
    }
}
